package queue

import (
	"app/internal/bootstrap"
	"app/pkg/queue"
	"context"
)

func init() {
	bootstrap.RegisterQueue(DemoQueue)
}

var DemoQueue = &qDemo{}

type qDemo struct {
	queue.Queue
}

func (q *qDemo) Topic() string {
	return "demo"
}

func (q *qDemo) Driver() string {
	return "redis"
}

func (q qDemo) Consume(ctx context.Context, msg queue.QueueMessgae) bool {
	//消息的消费逻辑 如果返回true则消息ack，否则nack
	return true
}
